package cn.doitedu.demo7;

import cn.doitedu.beans.UserAction;
import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

import java.io.IOException;

public interface RuleCalculator {

    String ruleId();

    boolean isNeedProcessPastData();


    void init(RuntimeContext runtimeContext, RuleMeta ruleMeta) throws IOException ;


    void calc(UserAction userAction, Collector<String> out) throws IOException;

}
